package com.shujia.datahub;

import com.aliyun.datahub.client.DatahubClient;
import com.aliyun.datahub.client.DatahubClientBuilder;
import com.aliyun.datahub.client.auth.AliyunAccount;
import com.aliyun.datahub.client.common.DatahubConfig;
import com.aliyun.datahub.client.http.HttpConfig;

public class DatahubUtil {
    public DatahubClient datahubClient;
    // Endpoint以Region: 华东1为例，其他Region请按实际情况填写
    String endpoint = "https://dh-cn-shanghai.aliyuncs.com";
    String accessId = "LTAIvXl3QTWkqvYc";
    String accessKey = "LUkTK7tY2meir3XuPfSa8RKmbuLQGU";

    public DatahubUtil(String projectName, String topic) {
        this.datahubClient = DatahubClientBuilder.newBuilder()
                .setDatahubConfig(
                        new DatahubConfig(endpoint,
                                // 是否开启二进制传输，服务端2.12版本开始支持
                                new AliyunAccount(accessId, accessKey), true))
                //专有云使用出错尝试将参数设置为           false
                // HttpConfig可不设置，不设置时采用默认值
                .setHttpConfig(new HttpConfig()
                        .setCompressType(HttpConfig.CompressType.LZ4) // 读写数据推荐打开网络传输 LZ4压缩
                        .setConnTimeout(10000))
                .build();

    }
}
